package com.gitee.source

import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.configuration.Configuration

object FlieSource {
  def main(args: Array[String]): Unit = {
    val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment

    // 本地文件
    env.readTextFile("file:///D:/data/input/a.txt").print()

    // hdfs上的文件
    env.readTextFile("hdfs://node01:9000/workcount/input/a.txt").print()

    // 读取csv文件
    // 报错Line could not be parsed: 直接更改后缀名不可以
    case class Student(id:Int,name:String)
    import org.apache.flink.api.scala._
    env.readCsvFile[Student]("file:///D:/data/input/a.csv").print()

    // 读取压缩文件(一堆乱码,毫无意义)
    env.readTextFile("file:///D:/data/input/a.zip").print()

    // 文件夹
    val parameters = new Configuration()
    parameters.setBoolean("recursive.file.enumeration",true)//表示递归读取
    env.readTextFile("hdfs://node01:9000/workcount/").withParameters(parameters).print()


  }

}
